package com.itlong.cloud.commons.thread.queue.process.queue;

import com.itlong.cloud.POJO.PO.SendPushMessageTaskPO;
import org.springframework.stereotype.Component;

import java.util.concurrent.DelayQueue;

/**
 * <desc>
 *      发送轮询指令至iot中心自定义队列
 * </desc>
 *
 * @createDate 2019/08/01
 */
@Component
public class SendIotPushMessageQueue {
    //发送呼梯消息至iot中心延迟队列
    private DelayQueue<SendPushMessageTaskPO> sendIotPushQueue = new DelayQueue();

    public DelayQueue<SendPushMessageTaskPO> getSendIotPushQueue() {
        return sendIotPushQueue;
    }
}
